package com.ktvme.core;

import java.io.File;
import java.util.List;

public interface FlinkJobService {
    // Job 相关操作
    List<JobInfo> getRunningJobs();
    List<JobInfo> getFinishedJobs();
    JobInfo getJobInfo(String jobId);
    void cancelJob(String jobId);
    void restartFailedJob(String jobId);

    // Jar 相关操作
    List<JarInfo> listJars();
    JarInfo uploadJar(File jarFile);
    void deleteJar(String jarId);

    // 运行 Jar
    String runJar(RunJarRequest request);
}

